package com.jdbc;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


import org.apache.commons.beanutils.BeanUtils;


/**
 * 利用Java针对MySql封装的jdbc框架类 JdbcUtils 完整实现(包含增删改查、JavaBean反射原理
 * 执行sql工具
 * 其中查询这块，包括普通的查询和利用反射完成的查询
 * */
public class BaseDao {
	// 初始化参数
	private PreparedStatement pstmt;
	private ResultSet rs;
	private Connection con;


	/**
	 * 通过反射机制查询多条记录
	 * 查询的通用方法
	 * @param sql
	 * @param params
	 * @param con  数据库链接
	 */
	public <T> List<T> queryList(String sql, List<Object> params,Class<T> clazz,String db){

		// 返回的集合
		List<T> list = new ArrayList<T>();
		try {
			// 对象
			T t = null;
			// 1. 获取连接  传进来（可能会用不同的链接）
			con = DbConnectionManager.getConnection(db);
			// 2. 创建stmt对象
			pstmt = con.prepareStatement(sql);
			// 3. 获取占位符参数的个数， 并设置每个参数的值
			//			int count = pstmt.getParameterMetaData().getParameterCount();
			//			System.out.println(count);

			if (params != null && !params.isEmpty()) {
				for (int i=0; i<params.size(); i++) {
					pstmt.setObject(i+1, params.get(i));
				}
			}
			// 4. 执行查询
			rs = pstmt.executeQuery();
			// 5. 获取结果集元数据
			ResultSetMetaData rsmd = rs.getMetaData();
			// ---> 获取列的个数
			int columnCount = rsmd.getColumnCount();

			// 6. 遍历rs
			while (rs.next()) {
				// 要封装的对象
				t = clazz.newInstance();

				// 7. 遍历每一行的每一列, 封装数据
				for (int i=0; i<columnCount; i++) {
					// 获取每一列的列名称
					String columnName = rsmd.getColumnName(i + 1);
					// 获取每一列的列名称, 对应的值
					Object value = rs.getObject(columnName);
					// 封装： 设置到t对象的属性中  【BeanUtils组件】
					BeanUtils.copyProperty(t, columnName, value);
				}
				// 把封装完毕的对象，添加到list集合中
				list.add(t);
			}
			pstmt.close();
		} catch (Exception e) {
			//						throw new RuntimeException(e);
			return null;
		} finally {
			releaseConn(pstmt, rs, con);
		}
		return list;
	}

	/**
	 * 通过反射机制查询单条记录
	 * 查询的通用方法
	 * @param sql
	 * @param params
	 * @param con  数据库链接
	 */
	public <T> T query(String sql, List<Object> params,Class<T> clazz,String db){
		// 对象
		T t = null;
		try {
			// 1. 获取连接  传进来（可能会用不同的链接）
			con = DbConnectionManager.getConnection(db);
			// 2. 创建stmt对象
			pstmt = con.prepareStatement(sql);
			// 3. 获取占位符参数的个数， 并设置每个参数的值
			//			int count = pstmt.getParameterMetaData().getParameterCount();
			//			System.out.println(count);

			if (params != null && !params.isEmpty()) {
				for (int i=0; i<params.size(); i++) {
					pstmt.setObject(i+1, params.get(i));
				}
			}
			// 4. 执行查询
			rs = pstmt.executeQuery();
			// 5. 获取结果集元数据
			ResultSetMetaData rsmd = rs.getMetaData();
			// ---> 获取列的个数
			int columnCount = rsmd.getColumnCount();

			// 6. 遍历rs
			while (rs.next()) {
				// 要封装的对象
				t = clazz.newInstance();

				// 7. 遍历每一行的每一列, 封装数据
				for (int i=0; i<columnCount; i++) {
					// 获取每一列的列名称
					String columnName = rsmd.getColumnName(i + 1);
					// 获取每一列的列名称, 对应的值
					Object value = rs.getObject(columnName);
					// 封装： 设置到t对象的属性中  【BeanUtils组件】
					BeanUtils.copyProperty(t, columnName, value);
				}
				// 把封装完毕的对象，添加到list集合中
			}
			pstmt.close();
		} catch (Exception e) {
			//						throw new RuntimeException(e);
			return null;
		} finally {
			releaseConn(pstmt, rs, con);
		}
		return t;
	}
	
	/**
	 * 查询返回map list
	 * @param sql
	 * @param params
	 * @param con  数据库链接
	 */
	public List<Map<String, Object>> queryReturnMapList(String sql, List<Object> params,String db){

		// 返回的map集合
		List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
		try {
			// 1. 获取连接  传进来（可能会用不同的链接）
			con = DbConnectionManager.getConnection(db);
			// 2. 创建stmt对象
			pstmt = con.prepareStatement(sql);
			// 3. 获取占位符参数的个数， 并设置每个参数的值
			//			int count = pstmt.getParameterMetaData().getParameterCount();
			//			System.out.println(count);

			if (params != null && !params.isEmpty()) {
				for (int i=0; i<params.size(); i++) {
					pstmt.setObject(i+1, params.get(i));
				}
			}
			// 4. 执行查询
			rs = pstmt.executeQuery();
			// 5. 获取结果集元数据
			ResultSetMetaData rsmd = rs.getMetaData();
			// ---> 获取列的个数
			int columnCount = rsmd.getColumnCount();

			// 6. 遍历rs
			while (rs.next()) {
				Map<String, Object> map = new HashMap<String, Object>();
				// 7. 遍历每一行的每一列, 封装数据
				for (int i=0; i<columnCount; i++) {
					// 获取每一列的列名称
					String columnName = rsmd.getColumnName(i + 1);
					// 获取每一列的列名称, 对应的值
					Object value = rs.getObject(columnName);
					// 放入map中
					map.put(columnName, value);
				}
				// map添加到list集合中
				list.add(map);
			}
			pstmt.close();
		} catch (Exception e) {
			//						throw new RuntimeException(e);
			return null;
		} finally {
			releaseConn(pstmt, rs, con);
		}
		return list;
	}

	/**
	 * 查询单条记录
	 * @param sql
	 * @param params
	 * @return
	 * @throws SQLException
	 */
	public Map<String, Object> queryReturnMap(String sql, List<Object> params,String db) {
		Map<String, Object> map = new HashMap<String, Object>();
		int index  = 1;
		try {
			// 1. 获取连接  传进来（可能会用不同的链接）
			con = DbConnectionManager.getConnection(db);
			// 2. 创建stmt对象
			pstmt = con.prepareStatement(sql);
			if(params != null && !params.isEmpty()){
				for(int i=0; i<params.size(); i++){
					pstmt.setObject(index++, params.get(i));
				}
			}
			rs = pstmt.executeQuery();//返回查询结果
			ResultSetMetaData metaData = rs.getMetaData();
			int col_len = metaData.getColumnCount();
			while(rs.next()){
				for(int i=0; i<col_len; i++ ){
					String cols_name = metaData.getColumnName(i+1);
					Object cols_value = rs.getObject(cols_name);
					if(cols_value == null){
						cols_value = "";
					}
					map.put(cols_name, cols_value);
				}
			}
			pstmt.close();
		} catch (Exception e) {
			//						throw new RuntimeException(e);
			return null;
		} finally {
			releaseConn(pstmt, rs, con);
		}
		return map;
	}


	/**
	 * 更新的通用方法
	 * @param sql   更新的sql语句(update/insert/delete)
	 * @param params  sql语句中占位符对应的值(如果没有占位符，传入null)
	 * @param con  数据库链接
	 */
	public boolean update(String sql,List<Object> params,String db){
		try {
			// 获取连接  传进来（可能会用不同的链接）
			con = DbConnectionManager.getConnection(db);
			// 创建执行命令的stmt对象
			pstmt = con.prepareStatement(sql);
			// 参数元数据： 得到占位符参数的个数
			int count = pstmt.getParameterMetaData().getParameterCount();

			// 设置占位符参数的值
			if (params != null && !params.isEmpty()) {
				// 循环给参数赋值
				for(int i=0;i<count;i++) {
					pstmt.setObject(i+1, params.get(i));
				}
			}
			// 执行更新
			pstmt.executeUpdate();
			pstmt.close();
		} catch (Exception e) {
			//			throw new RuntimeException(e);
			return false;
		} finally {
			releaseConn(pstmt, rs, con);
		}
		return true;
	}
	public void releaseConn(PreparedStatement pstmt,ResultSet rs,Connection con) {
		if (rs != null) {
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if (pstmt != null) {
			try {
				pstmt.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		DbConnectionManager.returnConnection(con);
	}

}
